package com.sdg.streaming

import org.apache.spark.SparkConf
import org.apache.spark.sql.SparkSession

object Test {
  def main(args: Array[String]): Unit = {
    val sparkConf = new SparkConf().setAppName("Test").setMaster("local")

    val spark = SparkSession.builder().config(sparkConf).getOrCreate()

    val rdd01 = spark.sparkContext.parallelize(Array((1,"a"),(2,"b"),(2,"b")))
    println(rdd01.collectAsMap())
    spark.stop()
  }

}
